package org.lzfto.flink.demo.business.flinkTest.enums;
/**
*测试基本信息
*@author lzfto
*@创建时间 2025年6月19日 14:25:34
*/
public enum FlinkTest {
	/**
	 * csv连接器测试-1
	 */
	FLINK_TEST_LOAD_CSV(1,"","","","CSV连接器测试"),
	/**
	 * 标准JDBC连接器测试-2
	 */
	FLINK_TEST_STD_JDBC_TEST(2,"","","","标准JDBC连接器测试"),
	/**
	 * 自定义JDBC连接器测试-3
	 */
	FLINK_TEST_CUST_JDBC_TEST(3,"","","","自定义JDBC连接器测试"),
	/**
	 * 自定义EXCEL连接器测试-4
	 */
	FLINK_TEST_LOAD_EXCEL(4,"","","","自定义EXCEL连接器测试"),
	/**
	 * MQTT源测试-5-来自于mqtt，写入JDBC,同时向前端ws输出信息
	 */
	FLINK_TEST_FROMMQTT_SINKTOJDBC(5,"sinkToJdbc","FLINK-MQTT-JDBC-DEV",
			"TOJDBC","MQTT源测试"),
	/**
	 * MQTT源和WEBSOCKET输出测试-6-来自于mqtt，进行计算,同时向前端ws输出信息。主要利用逻辑分区计算
	 */
	FLINK_TEST_FROMMQTT_SINKTOWEBSOCKET(6,"sinkToWebSocket","FLINK-MQTT-KEYBY",
			"TOWS","MQTT源和WEBSOCKET输出+逻辑分区测试"),
	/**
	 * MQTT源和WEBSOCKET输出测试-7-来自于mqtt，进行计算,同时向前端ws输出信息。主要利用物理分区计算
	 */
	FLINK_TEST_FROMMQTT_PARTITION(7,"sinkToWebSocket-partition","FLINK-MQTT-PARTITION",
			"PARTITION","MQTT源和WEBSOCKET输出+物理分区测试"),
	FLINK_TEST_DAMENG_JDBC(8,"sinkToWebSocket-DAMENG","FLINK-MQTT-DAMENG",
			"DAMENG","测试处理达梦数据库的自定义JDBC"),
	FLINK_TEST_CLICK_AND_WATERMARK(9,"sinkToWebSocket-WATERMARK","FLINK-MQTT-WATERMARK",
			"WATERMARK","点击事件的水印测试")
	;
	
	private Integer no;                   //测试序号
	private String  webSocketClientName;  //websocket客户端名称  
	private String  mqttClientName;    //mqtt客户端名称
	private String  mqttTopicSuffix;    //mqtt主题后缀
	private String  name; //测试名称
	
	FlinkTest(int no,String webSocketClientName,String mqttClientName,String mqttTopicSuffix,String name) {
		this.no=no;
		this.name=name;
		this.webSocketClientName=webSocketClientName;
		this.mqttClientName=mqttClientName;
		this.mqttTopicSuffix =mqttTopicSuffix;
	}
	public Integer getNo() {
		return no;
	}
	public String getName() {
		return name;
	}
	public String getWebSocketClientName() {
		return webSocketClientName;
	}
	public String getMqttTopicSuffix() {
		return mqttTopicSuffix;
	}
	public String getMqttClientName() {
		return mqttClientName;
	}
	
}
